package org.rcy.framework.mq.producer;

import org.rcy.framework.api.mq.AbstractMessage;

import java.util.concurrent.TimeUnit;

/**
 * @author 吴康桥
 * @Description
 * @date 2022/11/23 10:40
 */

public interface MessageProducer<M extends AbstractMessage>{
    void produce(M message);

    void produce(M message, Long delay, TimeUnit timeUnit);
}
